package org.rency.mq.kafka.producer.service;

import org.rency.common.utils.domain.BaseResult;
import org.rency.mq.kafka.producer.request.MessageEvent;

/**
 * 消息发送服务
 *
 * @author: Created by user_rcy@163.com on 2016/10/14.
 * @version: V1.0.0
 * @since JDK 1.8
 */
public interface MessagePublisher<K, V> {

    /**
     * 发送消息
     * @param request
     * @return
     */
    public BaseResult publish(MessageEvent<K, V> request);
}